f669aa9e2d36c2f256cbb46adc8f4a96caf0c941,src/main/java/org/influxdb/impl/InfluxDBImpl.java,InfluxDBImpl,write,#BatchPoints#,143

Before Change


	@Override
	public void write(final BatchPoints batchPoints) {
		this.batchedCount.addAndGet(batchPoints.getPoints().size());
		TypedString lineProtocol = new TypedString(batchPoints.lineProtocol());
		this.influxDBService.writePoints(
				this.username,
				this.password,
				batchPoints.getDatabase(),
				batchPoints.getRetentionPolicy(),
				TimeUtil.toTimePrecision(TimeUnit.NANOSECONDS),
				batchPoints.getConsistency().value(),
				lineProtocol);

	}

After Change


	@Override
	public void write(final BatchPoints batchPoints) {
		this.batchedCount.addAndGet(batchPoints.getPoints().size());
		RequestBody lineProtocol = RequestBody.create(MEDIA_TYPE_STRING, batchPoints.lineProtocol());
		execute(this.influxDBService.writePoints(
				this.username,
				this.password,
				batchPoints.getDatabase(),
				batchPoints.getRetentionPolicy(),
				TimeUtil.toTimePrecision(TimeUnit.NANOSECONDS),
				batchPoints.getConsistency().value(),
				lineProtocol));
	}

	@Override